package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.offline.pojo.Abnormal0200DataDetail;
import com.navinfo.tripanalysis.offline.pojo.DataCleaningInfo;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.sql.SparkSession;

public interface SaveDataCleaning0200DetailService {
    void save(SparkSession spark, JavaPairRDD<Long, Abnormal0200DataDetail> pairRDD, long d);

    void dropPartitions(SparkSession spark, long d);
}
